package server

import (
	"context"
	"example-damo/global"
	"example-damo/pro"
	"fmt"
	"google.golang.org/grpc"
	"time"
)

func SendMsg(uid int32) {
	//通过grpc 库 建立一个连接
	ADDRESS := global.UidConAddress[uid]
	conn, err := grpc.Dial(ADDRESS, grpc.WithInsecure())
	if err != nil {
		return
	}
	defer conn.Close()
	//通过刚刚的连接 生成一个client对象。
	c := pro.NewGreeterClient(conn)
	fmt.Println(conn)

	//客户端 推送 流
	putRes, _ := c.PutStream(context.Background())
	i := 1
	for {
		i++
		putRes.Send(&pro.StreamReqData{Data: "ss"})
		time.Sleep(time.Second)
		if i > 1 {
			break
		}
	}
}
